package main

import (
	"fmt"
	"io"
	"log"
	"net"
	"time"
)

func main() {
	listener, err := net.Listen("tcp", "localhost:8888")
	if err != nil {
		log.Fatal(err)
	}

	for {
		conn, err := listener.Accept()
		if err != nil {
			log.Fatal(err)
		}

		fmt.Println(" a client connected")

		// 不加 go, 只能服务一个客户端, 增加 go 可以服务多个客户端
		// java是event loop, work loop
		// go中是 go routine (协程)
		go handle(conn)
	}

}

func handle(conn net.Conn) {
	defer conn.Close()
	for {
		_, err := io.WriteString(conn, "hello")
		if err != nil {
			log.Fatal(err)
		}

		time.Sleep(1 * time.Second)
	}
}
